package com.j.lemon.learn.bookkeeper;

import org.apache.bookkeeper.client.BKException;
import org.apache.bookkeeper.client.BookKeeper;
import org.apache.bookkeeper.client.api.BookKeeperBuilder;
import org.apache.bookkeeper.conf.ClientConfiguration;
import org.apache.zookeeper.KeeperException;

import java.io.IOException;

/**
 * @Author lijunjun
 * @Date 2020/9/25 16:50
 * @Description
 */
public class BookkeeperClient {
    public static BookKeeper getClient() throws InterruptedException, BKException, IOException {
            String connectionString = "10.21.171.58:2181"; // For a single-node, local ZooKeeper cluster
        return new BookKeeper(connectionString);
    }
}
